package com.adcc.ags.utility.mq.transfer;

import com.adcc.ags.utility.mq.entity.Message;

/**
 * 异步消息接收监听器
 */
public interface AsyncMsgListener {

    /**
     * 消息接收响应事件
     * @param host
     * @param port
     * @param qm
     * @param name
     * @param message
     */
    public void onMessage(String host,int port,String qm,String name,Message message,int type);

}
